#!/bin/bash
# 定义数据源数组
arr_tab=(AML_CUSTOMER_MASTER AML_ACCOUNT_MASTER AML_TRANSACTION_DETAIL AML_UBO_INFO AML_WATCHLIST_MASTER AML_WATCHLIST_DETAIL AML_SCREENING_RESULT AML_ALERT AML_SUSPICIOUS_TXN_REPORT AML_MONITORING_RULE)

# 定义 ETL 时间
dt=`date -d '1 days ago' '+%y%m%d'`

# 遍历数组
echo "开始导入.."
for tab in "${arr_tab[@]}"
#FOR循环遍历
do

        echo "正在处理 $tab ==> ods_$tab .."
        echo ""
        sqoop import \
#导入数据
    --connect jdbc:oracle:thin:@192.168.4.110:1521:orcl \
#连接本地ip
    --username "SCOTT" \
    --password "123456" \
#输入用户名密码
    --table "$tab" \
#原表
    --hcatalog-database ods \
#定义数据库名称
    --hcatalog-table "ods_$tab" \
#定义目标表名称
    --hive-partition-key etl_date \
#定义分区(抽取时间T+1)
    --hive-partition-value "$dt" \
#定义具体时间
        -m 1 > /root/sqoop_ods_full_shao.log 2>&1
        if test $? -ne 0
        then
                echo "出现异常，结束程序！"
                echo '日志已写入 /root/sqoop_ods_full_shao.log'
                exit;
        fi
        echo ""
        echo "$tab ==> ods_$tab 处理完成！！"
done
echo "导入结束"